package com.jdrx.sw.sewage.dao;

import com.jdrx.platform.jdbc.dao.BaseDAO;
import com.jdrx.sw.sewage.beans.entity.StationWaterQualityPO;
import com.jdrx.sw.sewage.beans.vo.WaterQualityVO;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;

import java.time.LocalDateTime;
import java.util.List;
import java.util.Map;

@Mapper
public interface StationWaterQualityDAO extends BaseDAO<StationWaterQualityPO> {

    int batchInsert(Map<String, Object> params);

    List<WaterQualityVO> waterQualityMonitor(@Param("stationId") Long stationId,
                                             @Param("type") String type);

    StationWaterQualityPO findByStationIdAndTimeAndInOut(@Param("inOut") Integer inOut,
                                                         @Param("stationId") Long stationId,
                                                         @Param("createTime") LocalDateTime createTime,
                                                         @Param("dataNode") String dataNode);

    void updateById(StationWaterQualityPO waterQualityPO);
}